package com.cobra.rdd.operator.transform

import org.apache.spark.{SparkConf, SparkContext}

object Spark03_RDD_Operator_Transform_Par {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("Operator_Par")
    val sc = new SparkContext(sparkConf)
    val rdd = sc.makeRDD(List(1, 2, 3, 4))
    //rdd的计算一个分区内的数据是顺序执行
    //只有前面一个数据全部的逻辑执行完毕后才会执行下一个数据
    //分区内数据执行是有序的
    //不同分区数据计算是无序的
    val mapRDD = rdd.map(num => {
      println(">>>>>>>>" + num)
      num
    })
    val mapRDD1 =  mapRDD.map(num => {
      println("==========="+num)
      num
    })
    mapRDD1.collect()
    sc.stop()
  }
}
